//package cn.netty.service;
//
//import com.alibaba.fastjson.JSONObject;
//import com.netty.websocket.MiscHelper;
//import com.netty.websocket.WebSocketHandler;
//import io.netty.channel.Channel;
//
//public class OnlineHandler extends WebSocketHandler {
//    public OnlineHandler(){
//        //isErrClose=false;//出现异常 不关闭当前连接
//    }
//
//    //连接成功 断开 错误  更新  在线  离线标记
//    public void newMessage(String isOnline) throws Exception {
//        String sessionId = parameters.getString("sessionId");
//        if (sessionId != null && sessionId.length()>5) {
//            JSONObject message=new JSONObject(MiscHelper.isDebug);
//            message.put("msgType","online");
//            message.put("sessionId",sessionId);
//            message.put("isOnline",isOnline);
//            message.put("sockId",getSockId());
//            String datasource = parameters.getString("datasource");
//            if (datasource.equals("dbcon") || datasource.equals("dbscm") ||datasource.equals("scmdb") || datasource.equals("dbtest")
//                    || datasource.equals("dbhztest") ||datasource.equals("dbhzzc") ){
//                //给推流开发库 推流测试库 中策航运的后台服务 发送一条消息，更改数据库的用户在线 离线状态
//                sendMessage(datasource+"_Listener",message);
//            }
//            OnlineUserBiz.initOnline(parameters, message);//更新在线用户标记
//        }
//    }
//
//    @Override
//    public void onOpen() throws Exception {
//        newMessage("1");
//        String sessionId = parameters.getString("sessionId");
//        sendMessage("onlineAddRemove","上线广播 "+sessionId+" ");//在线用户页面自动刷新用
//    }
//
//    @Override
//    public void onMessage(JSONObject msgJSON) throws Exception {
//        String datasource = parameters.getString("datasource");
//        //在线用户消息处理
//        if (datasource!=null && msgJSON.getString("msgType")!=null && msgJSON.getString("msgType").equals("online")) {
//            parameters.put("queueShareMsg",false);//关闭在线用户发的消息 在当前队列中广播，节约流量
//            if (datasource.equals("dbcon") || datasource.equals("dbscm") ||datasource.equals("scmdb") || datasource.equals("dbtest")
//                    || datasource.equals("dbhztest") ||datasource.equals("dbhzzc") ){
//                //推流开发库 推流测试库 中策航运的后台服务 发送一条消息，更改数据库的用户在线 离线状态
//                sendMessage(datasource+"_Listener",msgJSON);
//            }
//            OnlineUserBiz.initOnline(parameters, msgJSON);//更新在线用户标记
//        }
//    }
//
//    @Override
//    public void onClosed() throws Exception {
//        newMessage("0");
//        String sessionId = parameters.getString("sessionId");
//        sendMessage("onlineAddRemove", "下线广播 " + sessionId + " ");//在线用户页面自动刷新用
//    }
//
//    @Override
//    public void onError(Throwable throwable) throws Exception {
//
//    }
//}